package RDD

import org.apache.spark.rdd.RDD
import org.apache.spark.{SparkConf, SparkContext}

object Spark01_RDD_Memory {

  def main(args: Array[String]): Unit = {

    // sc
    // local[*] 核模拟并行度 local 单线程
    val conf = new SparkConf().setAppName("spark").setMaster("local[*]")

    val sc = new SparkContext(conf)

    // create RDD

    //parallelize 并行度
    val rdd: RDD[Int] = sc.parallelize(Seq[Int](1, 2, 3, 4))
//    val rdd: RDD[Int] = sc.makeRDD(Seq[Int](1, 2, 3, 4))


    // close sc
    rdd.collect().foreach(println)
    sc.stop()
  }

}
